import org.apache.flink.api.common.functions.FlatMapFunction;
import org.apache.flink.api.common.functions.MapFunction;
import org.apache.flink.api.java.ExecutionEnvironment;
import org.apache.flink.api.java.operators.*;
import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.util.Collector;
import scala.collection.parallel.ParIterableLike;

public class Flink001_WordCount_Batch {
    public static void main(String[] args) {
        ExecutionEnvironment executionEnvironment = ExecutionEnvironment.getExecutionEnvironment();

        DataSource<String> stringDataSource = executionEnvironment.readTextFile("");
        System.out.println(123);
        System.out.println(12343546);
//        //FlatMapOperator<String, String> stringStringFlatMapOperator = stringDataSource.flatMap(new ParIterableLike.FlatMap());
//
//
//
//        //stringStringFlatMapOperator.map(new MapFunction<String, Tuple2<String, Integer>>() {
//            public Tuple2<String, Integer> map(String s) throws Exception {
//                return new Tuple2<String, Integer>(s,1);
//            }
//        });
    }
}
